package com.example.common.web.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.example.common.entity.mq.MqMessageEntity;

/**
 * <p>
 *     mq消息持久化接口
 * </p>
 *
 * @author zyred
 * @since v 0.1
 **/
public interface MqMessageService extends IService<MqMessageEntity> {

    void insertMessage(String id, String exchange, String routingKey, String className, Object message);

    void updateMessage(int status, String reason, String id);
}
